package com.lyq.database;

import com.lyq.bean.mySql.MysqlLinking;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.Map;

public class UpdateCourseTimes {
    public static void main(String[] args) {
        // 创建数据库连接
        MysqlLinking mysqlLinking = new MysqlLinking();
        mysqlLinking.getLink();
        Connection conn = MysqlLinking.conn;
        
        if (conn != null) {
            System.out.println("数据库连接成功！");
            
            // 定义课程时间更新映射
            Map<String, String> courseTimes = new HashMap<>();
            courseTimes.put("C001", "星期一 1-2节, 星期三 3-4节");
            courseTimes.put("C002", "星期二 1-2节, 星期四 3-4节");
            courseTimes.put("C003", "星期五 1-2节, 星期六 3-4节");
            courseTimes.put("C004", "星期一 3-4节, 星期四 1-2节");
            courseTimes.put("C005", "星期二 3-4节, 星期五 1-2节");
            courseTimes.put("C006", "星期三 1-2节, 星期六 1-2节");
            courseTimes.put("C007", "星期一 5-6节, 星期三 7-8节");
            courseTimes.put("C008", "星期二 5-6节, 星期四 7-8节");
            courseTimes.put("C009", "星期五 5-6节, 星期六 7-8节");
            courseTimes.put("C010", "星期一 7-8节, 星期四 5-6节");
            
            // 更新课程时间
            String sql = "UPDATE course SET C_Time = ? WHERE C_No = ?";
            
            try {
                PreparedStatement ps = conn.prepareStatement(sql);
                
                for (Map.Entry<String, String> entry : courseTimes.entrySet()) {
                    ps.setString(1, entry.getValue());
                    ps.setString(2, entry.getKey());
                    ps.executeUpdate();
                    System.out.println("已更新课程 " + entry.getKey() + " 的时间为: " + entry.getValue());
                }
                
                ps.close();
                System.out.println("所有课程时间更新完成！");
                
            } catch (SQLException e) {
                System.err.println("更新课程时间时发生错误: " + e.getMessage());
                e.printStackTrace();
            }
            
            // 关闭数据库连接
            try {
                conn.close();
                System.out.println("数据库连接已关闭。");
            } catch (SQLException e) {
                System.err.println("关闭数据库连接时发生错误: " + e.getMessage());
                e.printStackTrace();
            }
        } else {
            System.err.println("数据库连接失败！");
        }
    }
}